package com.partsoft.dits.mq;

import org.springframework.beans.factory.BeanNameAware;

import com.partsoft.dits.BroadcastIntegrateDescriptor;
import com.partsoft.dits.DataEdgeDescriptor;

/**
 * MQ队列广播描述符
 */
public class MQQueueBroadcastDescriptor extends BaseMQQueueDescriptor implements
		BroadcastIntegrateDescriptor, BeanNameAware {
	
	private String dataDescriptorId;
	
	private Class<? extends DataEdgeDescriptor> dataClass;
	
	public MQQueueBroadcastDescriptor() {}
	

	public Class<? extends DataEdgeDescriptor> getDataClass() {
		return dataClass;
	}

	public void setDataClass(Class<? extends DataEdgeDescriptor> dataClass) {
		this.dataClass = dataClass;
	}
	
	public String getDataDescriptorId() {
		return dataDescriptorId;
	}

	public void setDataDescriptorId(String dataDescriptorId) {
		this.dataDescriptorId = dataDescriptorId;
	}

	@Override
	public MQQueueBroadcastDescriptor clone() {
		return (MQQueueBroadcastDescriptor) super.clone();
	}
	
	@Override
	public String toString() {
		return String.format("数据发送至MQ(%s)", getConnectPool());
	}

}
